package com_atguigu_sprinboot.controller;

import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

/**
 * 模拟Consumer消费消息
 */
@Service
@Slf4j
public class KafkaConsumer {
    @KafkaListener(id = "email", topics = "first")
    public void emailListen(String input) {
        log.info("email consumer: {}", input);
    }
}

